package cn.hackcloud.concurrency.eda;

public interface Channel<E extends Message> {
    /**
     * 负责消息的调度
     */
    void dispatch(E message);
}
